//package com.wanlian.socketserver.Device.worker;
//
//import com.wanlian.common.KeyPara;
//import com.wanlian.util.HttpUtils;
//import com.wanlian.util.PostQueue;
//
//import java.util.List;
//import java.util.concurrent.ExecutorService;
//import java.util.concurrent.Executors;
//import java.util.concurrent.TimeUnit;
//
//public class DevicePostQueueWorker {
//    /**
//     * 定时获取所有路由器共享设置
//     */
//    public static void work() {
//        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
//        for (int i = 0; i < 10; i++) {
//            fixedThreadPool.execute(new Runnable() {
//                public void run() {
//                    while (true) {
//                        try {
//                            TimeUnit.MILLISECONDS.sleep(100);
//                            processPostQueue();
//                        } catch (Exception e) {
//                            //e.printStackTrace();
//                        }
//                    }
//                }
//            });
//        }
//    }
//
//    private static synchronized void processPostQueue() {
//        try {
//            System.out.println("posturl msg size:" + PostQueue.size());
//            List<KeyPara> keyParas = PostQueue.get(1000);
//            System.out.println("posturl msg size:" + PostQueue.size());
//            for (KeyPara item : keyParas) {
//                try {
//                    HttpUtils.sendPost(item.getKey(), item.getValue());
//                } catch (Exception e) {
//                    e.printStackTrace();
//                }
//            }
//        } catch (Exception e) {
////            e.printStackTrace();
//        }
//    }
//
//
//}
